package com.subframe7536.UserInfo.message;

import lombok.extern.slf4j.Slf4j;

//@Component
@Slf4j
public class consumer {

//    @KafkaListener(topics = "login", groupId = "3")
//    public void listen(ConsumerRecord<String, String> record, Acknowledgment ack) {
//        String value = record.value();
//        log.debug("value={},record={}", value, record);
//        //手动提交offset
//        ack.acknowledge();
//    }

}
